package task

import (
	"fmt"
	"gf-start-kit/plugins/job/service"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/util/gconv"
)

func Test(cronKey string) error {
	g.Log().Infof("当前执行定时器,%s", cronKey)
	return nil
}

var s = new(service.JobService)

//公用url模式请求方法，根据cronKey获取执行的参数
func UrlQuery(cronKey string) error {
	ent, _ := s.Get(gconv.Int64(cronKey))
	if g.IsEmpty(ent) {
		g.Log().Info("没找到当前执行的方法数据", cronKey)
		return nil
	}
	if ent.Url == "" {
		g.Log().Info(fmt.Sprintf("UrlQuery必须的url不存在%s", cronKey))
		return nil
	}
	g.Log().Info(fmt.Sprintf("当前执行定时器%s", cronKey))
	c := g.Client()
	if r, err := c.Get(ent.Url, ent.Param); err != nil {
		g.Log().Infof("请求[%s]错误,参数:%s", ent.Url, ent.Param)
		return err
	} else {
		defer r.Close()
		g.Dump(r.ReadAllString())
	}
	return nil
}
